const mysql = require('mysql');

function query(sql, params = []) {
    // resolve 函数，在异步方法处理成功，返回成功数据时，使用该函数
    // reject 函数，在异步方法处理失败，返回错误信息时，使用该函数
    return new Promise((resolve, reject) => {
        // 创建连接配置
        const con = mysql.createConnection({
            host: 'localhost',
            user: 'root',
            password: 'root',
            database: 'api-koa',
        });

        // 连接数据库
        con.connect();

        // 执行 sql 语句
        con.query(sql, params, function(error, results, fields) {
            if (error) {
                reject(error);
            } else {
                resolve(results);
            }
        });

        // 关闭连接
        con.end();
    });
}

module.exports = { query };
